package org.example.mq.mqserver.core;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {
    void handleDelivery(String consumerTag,BasicProperties basicProperties,byte[] body) throws IOException;
}
